/**
 * Created by ryansecreat on 2017/12/25.
 */


module.exports = agent => {
    // 在这里写你的初始化逻辑

    // 也可以通过 messenger 对象发送消息给 App Worker
    // 但需要等待 App Worker 启动成功后才能发送，不然很可能丢失
    agent.messenger.on('egg-ready', () => {
        const data = { name:"ryanche"};
        agent.messenger.sendToApp('hello', data);
    });

    /*class ClusterStrategy extends agent.ScheduleStrategy {
     start() {
     // 订阅其他的分布式调度服务发送的消息，收到消息后让一个进程执行定时任务
     // 用户在定时任务的 schedule 配置中来配置分布式调度的场景（scene）
     agent.mq.subscribe(schedule.scene, () => this.sendOne());
     }
     }
     agent.schedule.use('cluster', ClusterStrategy);*/
};